package com.lixl.activemq;

import javax.jms.JMSException;

public class TopicsDemo {

	public static void main(String[] args) {

	}

}

/**
 * 发布者
 * @author Administrator
 *
 */
class Publisher extends AbstractActiveMQThread{
	
	public Publisher() throws JMSException {
		super();
		session.createTopic("TodayNews");
		
	}
	
}
